fairnesscoop / pictyschool

@CommandHandler(CreateIngestionCommand)

export class CreateIngestionCommandHandler {

  constructor(

    @Inject('ISchoolRepository')

    private readonly schoolRepository: ISchoolRepository,

    @Inject('IIngestionRepository')

    private readonly ingestionRepository: IIngestionRepository,

  ) {}

  public async execute(command: CreateIngestionCommand): Promise<string> {

    const { schoolId } = command;

    const school = await this.schoolRepository.findOneById(schoolId);

    if (!school) {

      throw new SchoolNotFoundException();

    }

    const ingestion = await this.ingestionRepository.save(

      new Ingestion(

        school

      )

    );

    return ingestion.getId();